package crond

import (
	"advertising/config/redis"

	consumer "192.168.1.75/go-pkg/timer-consumer"
)

func CrondInit() {
	timerConsumer := consumer.New("system:timer-schedule:", "advertising", redis.NewDB())
	// 添加任务
	timerConsumer.AddFunc("publishScheduleChangeStatus", PublishScheduleChangeStatus) // 定时更新投放计划状态
	// 启动定时任务
	timerConsumer.Start()
}
